b737a232d34b1ccdb399fdc2147106f7eeff6615,src/main/java/com/steelbridgelabs/oss/neo4j/structure/Neo4JSession.java,Neo4JSession,loadEdge,#Record#,521
Before Change
Object firstNodeId = firstNode.get(vertexIdFieldName).asObject();
Object secondNodeId = secondNode.get(vertexIdFieldName).asObject();
// check edge has been deleted (one of the vertices was deleted)
if (deletedVertices.contains(firstNodeId) || deletedVertices.contains(secondNodeId) || (!partition.isEmpty() && (!StreamSupport.stream(firstNode.labels().spliterator(), false).anyMatch(partition::contains) || !StreamSupport.stream(secondNode.labels().spliterator(), false).anyMatch(partition::contains))))
return null;
// check we have first vertex in memory
Neo4JVertex firstVertex = vertices.get(firstNodeId);
After Change
Object firstNodeId = firstNode.get(vertexIdFieldName).asObject();
Object secondNodeId = secondNode.get(vertexIdFieldName).asObject();
// check edge has been deleted (one of the vertices was deleted) or the vertices are not in the read partition
if (deletedVertices.contains(firstNodeId) || deletedVertices.contains(secondNodeId) || !partition.containsVertex(StreamSupport.stream(firstNode.labels().spliterator(), false).collect(Collectors.toSet())) || !partition.containsVertex(StreamSupport.stream(secondNode.labels().spliterator(), false).collect(Collectors.toSet())))
return null;
// check we have first vertex in memory
Neo4JVertex firstVertex = vertices.get(firstNodeId);